package com.zhouqinuan.spring.cloud.develop.framework.demo.kafka.message.topic;

import org.apache.kafka.clients.admin.NewTopic;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class KafkaTopicConfiguration {

	@Bean(name = KafkaTopic.UserInfo.name)
	public NewTopic userInfoTopic() {
		return new NewTopic(KafkaTopic.UserInfo.name, KafkaTopic.UserInfo.numPartitions, KafkaTopic.UserInfo.replicationFactor);
	}
}
